package com.example.aigc_education.integration;

import com.example.aigc_education.integration.request.ChatMessageRequest;
import com.example.aigc_education.rpc.api.*;
import io.grpc.stub.StreamObserver;

public interface ChatServiceIntegration {

    /**
     * Stream 流式对话
     * @param request 用户消息
     * @param responseObserver 响应观察者
     */
   void stream(ChatMessageRequest request, StreamObserver<ChatServiceProto.ChatMessage> responseObserver);


    /**
     * 同步对话
     * @param userMessage 用户消息
     * @return ChatServiceProto.ChatMessage
     */
   ChatServiceProto.ChatMessage invoke(ChatServiceProto.ChatMessage userMessage);
}
